package org.cybergarage.upnp.event;

import java.io.InputStream;

import org.cybergarage.http.HTTPRequest;

public class SubscriptionMUServerThread extends Thread {

	private InputStream in = null;
	private SubscriptionMUServer server = null;
	
	public SubscriptionMUServerThread(SubscriptionMUServer server, InputStream	in){
		this.server = server;
		this.in = in;
	}

	
	public void run(){
		HTTPRequest req = new HTTPRequest();
		req.init();
		
		while(req.set(in) == true){
			server.performRequestListener(req);
		}
	}
}
